"""
pyspark基础准备：
    1.通过pip 安装pyspark
    2.构建SparkContext对象作为使用pyspark的统一执行入口
"""
# 导包
from pyspark import SparkConf, SparkContext

# 构建SparkConf对象
conf = SparkConf().setMaster("local[*]").setAppName("test_spark_app")

# 基于SparkConf对象构建SparkContext对象
sc = SparkContext(conf=conf)

# 获取pyspark版本
print(f"pyspark version = {sc.version}")
# 关闭sc，停止pyspark程序
sc.stop()
